import { Injectable } from '@nestjs/common';
import Bull, { Job, Queue } from 'bull';
import { InjectQueue, OnGlobalQueueCompleted, OnQueueActive, Process, Processor } from '@nestjs/bull';
import { log } from 'console';
import { sleep } from 'src/util/sleep.util';

@Injectable()
export class QueueService {
  constructor(@InjectQueue('audio') private audioQueue: Queue) {
  }
  async addTask(data :any,option ?:Bull.JobOptions){
      return  this.audioQueue.add(data,option)
       
  }
}


